google.golang.org/grpc/internal/transport.Stream.ctx (field)
25 uses
google.golang.org/grpc/internal/transport (current package)
client_stream.go#L93: case <-s.ctx.Done():
client_stream.go#L96: s.Close(ContextErr(s.ctx.Err()))
handler_server.go#L416: ctx: ctx,
handler_server.go#L428: reader: &recvBufferReader{ctx: s.ctx, ctxDone: s.ctx.Done(), recv: s.buf},
http2_client.go#L502: s.ctx = ctx
http2_client.go#L505: ctx: s.ctx,
http2_client.go#L506: ctxDone: s.ctx.Done(),
http2_client.go#L915: sh.HandleRPC(s.ctx, outHeader)
http2_client.go#L1255: if d, ok := s.ctx.Deadline(); ok && !d.After(time.Now()) {
http2_client.go#L1594: sh.HandleRPC(s.ctx, inHeader)
http2_client.go#L1601: sh.HandleRPC(s.ctx, inTrailer)
http2_server.go#L540: s.ctx, s.cancel = context.WithTimeout(ctx, timeout)
http2_server.go#L542: s.ctx, s.cancel = context.WithCancel(ctx)
http2_server.go#L547: s.ctx = metadata.NewIncomingContext(s.ctx, mdata)
http2_server.go#L584: if s.ctx, err = t.inTapHandle(s.ctx, &tap.Info{FullMethodName: s.method, Header: mdata}); err != nil {
http2_server.go#L604: if s.ctx.Err() != nil {
http2_server.go#L646: s.ctxDone = s.ctx.Done()
http2_server.go#L650: ctx: s.ctx,
http2_server.go#L1005: return ContextErr(s.ctx.Err())
server_stream.go#L123: s.ctx = ctx
transport.go#L289: ctx context.Context // the associated context of the stream
transport.go#L333: return s.ctx